package com.wenge.datagroup.storage.service;

import com.wenge.datagroup.storage.bean.Topic;
import com.wenge.datagroup.storage.future.AsyncProcessCreater;

import com.alibaba.fastjson.JSONObject;
import org.apache.spark.broadcast.Broadcast;

public interface TransformService {

    void transferData(
            JSONObject doc,
            Topic topic,
            Broadcast<AsyncProcessCreater> asyncBro);
}
